package imp

import (
	"fmt"
	"gf-start-kit/library/mq/interfaces"
)

//示例其他工厂
type FileQueuePCreate struct {
}
type FileQueueProducer struct {
}

func (p *FileQueueProducer) Pub(msg string) {
	fmt.Println("FileQueueProducer")
}
func (p *FileQueueProducer) SetTopic(topic string) interfaces.IMQProducer {
	fmt.Println("FileQueueProducer")
	return p
}
func (c *FileQueuePCreate) Create() interfaces.IMQProducer {
	return &FileQueueProducer{}
}
